<?php	
	//-----------------------------------------------
	//连数据库
	function connect(){
		$link = @mysqli_connect(HOST,USER,PWD,DBNAME);
		if($errno = mysqli_connect_errno()){ //判断连接的错误
			die('<br /><b>Error 连接数据库失败 '.$errno.' : </b>'.mysqli_connect_error().'<br />');
		}
		mysqli_set_charset($link,CHARSET);   //设置连接字符集
		return $link;                        //返回连接的资源
		mysqli_close($link);
	}
	//-----------------------------------------------
	//增加记录
	function insert(){
		$link = connect();    //获取连接源
		$flag = false;
		foreach($_POST as $k=>$v){
			if($v == ''){    //过滤空提交
                continue;
            }
			$fields[] = $k;    //收集字段
			$values[] = "'$v'";//收集群值
			$flag = true;
		}
		if($flag){
			$fields = implode(',',$fields);//拼接字段
			$values = implode(',',$values);//拼接群值
			$sql = "INSERT INTO $_GET[tblname] ($fields) VALUES($values)";//拼接整条sql语句
			$res = mysqli_query($link,$sql);       //执行sql语句
			if($res){//判断语句执行是否失败
				if(mysqli_affected_rows($link)>0){ //判断执行效果
					return mysqli_insert_id($link);//插入成功返回插入ID---------------√
				}else{
					return false;				   //插入失败返回false ---------------√
				}
			}else{//语句执行错误输出sql语句
				 $err = mysqli_error($link);
				 if(stripos($err,"for key 'uname'")){
					 echo '<b>用户名不可重复!</b>';
				 }else{
					 die('<br /><b>'.$sql.'</b><br />'.$err.'<br />');
				 }
			}
		}
		mysqli_close($link);//关闭连接
	}
	//-----------------------------------------------
	//删除记录
	function delete(){
		$link = connect();
		$sql = "DELETE FROM $_GET[tblname] WHERE $_GET[pk] = $_GET[id]";
		$res = mysqli_query($link,$sql);
		if($res){
			if(mysqli_affected_rows($link)){
				return true; //删除成功返回true --------------√
			}else{
				return false;//删除失败返回false--------------√
			}
		}else{
			die('<br /><b>'.$sql.'</b><br />'.mysqli_error($link).'<br />');
		}
		mysqli_close($link);
	}
	//-----------------------------------------------
	//修改记录
	function update(){
		$link = connect();
		foreach($_POST as $k=>$v){
			if($k == 'id'){
                continue;
            }
			$fields[] = $k."='$v'";
		}
		$fields = implode(',',$fields);
		$sql = "UPDATE $_GET[tblname] SET $fields WHERE $_GET[pk] = $_GET[id]";
		$res = mysqli_query($link,$sql);
		if($res){
			if(mysqli_affected_rows($link)){
				return true; //修改成功返回true --------------√
			}else{
				return false;//修改失败返回false--------------√
			}
		}else{
			$err = mysqli_error($link);
				 if(stripos($err,"for key 'uname'")){
					 echo '<b>用户名不可重复!</b>';
				 }else{
					 die('<br /><b>'.$sql.'</b><br />'.$err.'<br />');
				 }
		}
		mysqli_close($link);
	}
	//-----------------------------------------------
	//查询数据
	function select($condition = ''){
		$link = connect();
		$sql = "SELECT * FROM $_GET[tblname] $condition";
		$res = mysqli_query($link,$sql);
		if($res){
			if(mysqli_num_rows($res)>0){
				return mysqli_fetch_all($res,MYSQLI_ASSOC);//修改成功返回结果  --------------√
			}else{
				return false;                              //修改失败返回false --------------√
			}	
		}else{
			die('<br /><b>'.$sql.'</b><br />'.mysqli_error($link).'<br />');
		}
		mysqli_free_result($res);//释放结果集
		mysqli_close($link);
	}
	//-----------------------------------------------
	//查记录数
	function rowCount($condition = ''){
		$link = connect();
		$sql = "SELECT COUNT(*) num FROM $_GET[tblname] $condition";
		$res = mysqli_query($link,$sql);
		if($res){
			return mysqli_fetch_all($res,MYSQLI_ASSOC)[0]['num'];//成功返回记录数
		}else{
			return false;                                 //失败返回false
		}
	}